package com.whynot.frame.stream.mq.config;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * 描    述:消息队列
 * 创建时间: 2018/12/20
 */
public interface MessageMQ {
    String WECHAT_SEND_OUTPUT = "send_msg_output";
    String WECHAT_SEND_INPUT = "send_msg_input";
    String WECHAT_RECEIVE_OUTPUT = "receive_msg_output";
    String WECHAT_RECEIVE_INPUT = "receive_msg_input";

    @Output(WECHAT_SEND_OUTPUT)
    MessageChannel sendMsgOutput();

    @Input(WECHAT_SEND_INPUT)
    SubscribableChannel sendMsgInput();

    @Output(WECHAT_RECEIVE_OUTPUT)
    MessageChannel receiveMsgOutput();

    @Input(WECHAT_RECEIVE_INPUT)
    SubscribableChannel receiveMsgInput();
}